package org.mq.mymq.broker.utils;

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 * @ClassName UnfailReentrantLock
 * @Description 非公平锁
 * @Author jiarong_ye
 * @Date 2025/6/16 15:09
 * @Version 1.0
 */
public class UnfairReentrantLock implements PutMessageLock {
    private Lock lock = new ReentrantLock();
    @Override
    public void lock() {
        lock.lock();
    }

    @Override
    public void unlock() {
        lock.unlock();
    }
}
